package com.whale.cloud.util.kafka;

import org.apache.kafka.clients.producer.RecordMetadata;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaOperations;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.kafka.support.ProducerListener;
import org.springframework.stereotype.Component;
import lombok.Data;

/** Created by Abel on 2017/5/25. */
@Data
@Component
public class MKafkaProducer {

  //  @Autowired private KafkaTemplate kafkaTemplate;

  //  public void send(String topic, String data) {
  //
  //    kafkaTemplate.send(topic, data);
  //    kafkaTemplate();
  //    kafkaTemplate.execute(
  //        new KafkaOperations.ProducerCallback<String, String, Object>() {
  //          @Override
  //          public Object doInKafka(
  //              org.apache.kafka.clients.producer.Producer<String, String> producer) {
  //            return null;
  //          }
  //        });
  //
  //    //消息发送的监听器，用于回调返回信息
  //    kafkaTemplate.setProducerListener(
  //        new ProducerListener<String, String>() {
  //          @Override
  //          public void onSuccess(
  //              String topic,
  //              Integer partition,
  //              String key,
  //              String value,
  //              RecordMetadata recordMetadata) {}
  //
  //          @Override
  //          public void onError(
  //              String topic, Integer partition, String key, String value, Exception exception) {}
  //
  //          @Override
  //          public boolean isInterestedInSuccess() {
  //            return false;
  //          }
  //        });
  //  }
}
